#include "user_function.h"
#include"admin_function.h"




void user_function(int user_judge, int listenfd)
{
	if (user_judge == 1) {
		printf("用户进入功能界面成功\n");

		char buf[1024] = { 0 };
		memset(buf, 0, sizeof(buf));
		pump_list(listenfd);
		int ret = 0;
		printf("等待客户端发送中---\n");
		ret = recv(listenfd, buf, 1024, 0);
		if (ret < 0) {
			perror("recv");
			return;
		}
		if (ret == 0) {
			printf("用户退出功能界面\n");
			return;
		}
		printf("本次接收的字节大小是：%d\n", ret);
		printf("刚收到并未解析的数据：%s\n", buf);

		// 解析json
		cJSON* json = NULL;
		json = cJSON_Parse(buf);
		cJSON* node = NULL;
		node = cJSON_GetObjectItem(json, "data_type");
		if (node == NULL) {
			printf("小type错误，为空\n");
			exit(-1);
		}

		if (node->type == cJSON_Number) {//判断是查询最新数据还是查询历史数据
			if (node->valueint == 1) {//查询最新数据
				int pump_id = 0;
				node = cJSON_GetObjectItem(json, "pump_id");
				if (node == NULL) {
					printf("用户要查看的pump_id是空\n");
					exit(-1);
				}
				if (node->type == cJSON_Number) {
					pump_id = node->valueint;//获取客户端具体要查看的水泵号
				}
				printf("用户要查看的pump_id是%d\n", pump_id);
				//把水泵号给到函数
				new_data_list(listenfd, pump_id);




			}
			else if (node->valueint == 2) {//查询历史数据
				int pump_id = 0;
				node = cJSON_GetObjectItem(json, "pump_id");
				if (node == NULL) {
					printf("用户要查看的pump_id是空\n");
					exit(-1);
				}
				if (node->type == cJSON_Number) {
					pump_id = node->valueint;//获取客户端具体要查看的水泵号
				}
				printf("用户要查看的pump_id是%d\n", pump_id);
				all_data_list(listenfd, pump_id);






			}
		}

	}
	else {
		printf("用户进入功能界面失败\n");
	}
}


